package jms.mq;

import java.util.logging.Logger;

/**
 * 测试MQ
 */

public class ProduceClient {
    private static Logger logger = Logger.getGlobal();

    public static void main(String[] args) throws Exception {
        MyClient client = new MyClient();
        client.produce("SEND: hello  MQ");

    }

}

class ConsumeClient {
    private static Logger logger = Logger.getGlobal();


    public static void main(String[] args) throws Exception {
        MyClient client = new MyClient();
        String msg = client.consume();

        logger.info(String.format("获取的消息是: s%", msg));
    }
}